package com.jzl.canal_consumer.etl.load.mysql;

import com.alibaba.otter.canal.protocol.CanalEntry;

import java.util.List;

/**
 * @author ZhenWuWang
 */
public interface SqlExecutor
{
    int[] batchExecute(CanalEntry.Header header, List<List<CanalEntry.Column>> columns);

    int execute(final CanalEntry.Header header, List<CanalEntry.Column> columns);
}
